package com.titan.single.constant;

public class KafkaConstant {

    // 标签
    //字符串信息消费测试 标签
    public static final String TOPIC_MSG = "topic_msg";

    //带有key的消息测试 标签
    public static final String TOPIC_KEY = "topic_key";

    // JSON对象消费测试 标签
    public static final String TOPIC_JSON_MSG = "topic_json_msg";

    // 分组
    public static final String GROUP_TIAN = "group_titan";

    // canal-admin 打过来的标签
    public static final String CANAL_TOPIC = "canal_topic";


}
